37297389d504a031e2adbf5ab9dae4f7b430e766,src/test/java/org/springframework/integration/kafka/listener/DefaultConnectionTests.java,DefaultConnectionTests,testFetchPartitionMetadata,#,51

Before Change


	public void testFetchPartitionMetadata() throws Exception {
		createTopic(TEST_TOPIC, 1, 1, 1);
		Connection brokerConnection =
				new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 10000);
		Partition partition = new Partition(TEST_TOPIC, 0);
		Result<Long> result = brokerConnection.fetchInitialOffset(-1, partition);
		Assert.assertEquals(0, result.getErrors().size());

After Change


	public void testFetchPartitionMetadata() throws Exception {
		createTopic(TEST_TOPIC, 1, 1, 1);
		Connection brokerConnection =
				new DefaultConnection(getKafkaRule().getBrokerAddresses()[0], "client", 64*1024, 3000, 1, 10000);
		Partition partition = new Partition(TEST_TOPIC, 0);
		Result<Long> result = brokerConnection.fetchInitialOffset(-1, partition);
		Assert.assertEquals(0, result.getErrors().size());